package com.ruoyi.iot.service;

import com.ruoyi.iot.domain.mqtt.MqttMessage;
import com.ruoyi.iot.domain.mqtt.WillMqttMessage;

/**
 * @Author: orange
 * @CreateTime: 2025-02-14
 */
public interface IYFHandleMqttMessageService {
    /**
     * 处理mqtt消息
     *
     * @param mqttMessage mqtt 实体参数
     * @param topic       订阅的主题
     */
    void handle(MqttMessage mqttMessage, String topic);

    /**
     * 遗嘱消息处理
     *
     * @param message 遗嘱消息实体参数
     * @param topic   订阅的主题
     */
    void handleWill(WillMqttMessage message, String topic);
}
